package com.ms.service.module.fish.message;

import java.nio.ByteBuffer;

import com.xpec.c4.net.codec.ManualCodec;

public class FishManualCodec implements ManualCodec {

	private IWrite msg;
	
	public FishManualCodec(IWrite msg) {
		this.msg = msg;
	}
	
	@Override
	public byte[] encode() {
		byte[] src = msg.getByteArray();
		if(src == null){
			ByteBuffer ib = ByteBuffer.allocate(1024);
			msg.write(ib);
			ib.flip();
			src = new byte[ib.remaining()];
			ib.get(src);
			msg.setByteArray(src);
		}
		return src;
	}

	@Override
	public void decode(byte[] bytes) {
		
	}
}

